//package net.neptech.listener;
//import net.neptech.service.AsrService;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.messaging.handler.annotation.Header;
//import org.springframework.messaging.handler.annotation.Payload;
//import org.springframework.stereotype.Component;
//import org.springframework.stereotype.Service;
//
//@Service
//public class AudioConsumer {
//
//    @Autowired
//    private AsrService asrService;
//
//    @KafkaListener(topics = "lxy-audio-chunk", groupId = "ai-summary-group")
//    public void consumeAudio(@Payload byte[] audioData,
//                             @Header("kafka_receivedMessageKey") String conferenceId) {
//        System.out.println("🎧 AI 模块收到音频: " + conferenceId + ", size=" + audioData.length);
//        asrService.processAudioChunk(conferenceId, audioData);
//    }
//}